package com.tx.server.message;

import org.springframework.cloud.stream.annotation.Input;
import org.springframework.cloud.stream.annotation.Output;
import org.springframework.messaging.MessageChannel;
import org.springframework.messaging.SubscribableChannel;

public interface StreamClient {

    String STREAMINPUT = "myMessage-input";
    String STREAMOUTPUT = "myMessage-output";

    @Input(STREAMINPUT)
    SubscribableChannel input();  // 订阅通道

    @Output(STREAMOUTPUT)
    MessageChannel output();  // 消息通道
}
